package com.bff.gaia.streaming.api.mo.gaia.api;

import com.bff.gaia.api.common.functions.FlatMapFunction;
import com.bff.gaia.util.Collector;

import java.util.HashMap;

public abstract class FlatMapExtend<T, O> implements FlatMapFunction<T, O> {
	private T data;
	private HashMap hashMap;
	private boolean flag = true;
	private String addresss;
	public void flatMap(T value, Collector<O> out) throws Exception {
		if (this.flag)
			setup();
	}
	public void setup(T value, String address) {}
	public void setup() {}
	public void cleanup(Collector<O> out) {}
	public void Cache() {}
	public void Cache(T value) {}
}